package com.ybliang.plat.cms.schedule.kafka.cosumer;

public interface PlatKafkaConsumer {

    public String subscribeTopic();


    public void consumer(String messageType, ConsumerHandler consumerHandler);



}
